package com.lzy.canal.component.consumer.mysql;


import com.lzy.canal.component.consumer.MysqlConsumer;
import com.lzy.canal.component.result.mysql.DefaultConsumerDdlRestData;
import com.lzy.canal.component.row.CanalRow;

import java.util.List;

/**
 * ddl语句处理器
 *
 */
public interface DdlConsumer extends MysqlConsumer<DefaultConsumerDdlRestData> {

    /**
     * 处理ddl语句
     *
     * @param row 行数据
     * @return
     */
    @Override
    List<DefaultConsumerDdlRestData> consumer(CanalRow row);

}
